#include "msgCallback.h"

void client_message_call_back(zmq::socket_t *socket, zmsg &msg, std::string &identity, const char *message)
{
    std::cout << "client: " << message << std::endl;
}

void client_append_call_back(std::string &identity)
{
    std::cout << "client " << identity << " add" << std::endl;
}

void client_quit_call_back(std::string &identity)
{
    std::cout << "client " << identity << " quit" << std::endl;
}

void service_message_call_back(zmq::socket_t *socket, zmsg &msg, std::string &identity,const char *message)
{
    std::cout << "client message:" << message << std::endl;
}


void service_message_call_back(zmq::socket_t *socket, zmsg &msg, std::vector<worker_t> &queue, std::string &identity,const char *message)
{
    std::cout << "client size:" << queue.size() << std::endl;
    std::cout << "client message:" << message << std::endl;
}

void client_append_call_back(std::vector<worker_t> &queue, std::string &identity)
{
    std::cout << "client size:" << queue.size() << std::endl;
    std::cout << "client " << identity << " add" << std::endl;
}

void client_quit_call_back(std::vector<worker_t> &queue, std::string &identity)
{
    std::cout << "client size:" << queue.size() << std::endl;
    std::cout << "client " << identity << " quit" << std::endl;
}

void client_message_call_back(const char *message,const char *topic)
{
     std::cout << "[" << topic << "] " << message << std::endl;
}

void client_message_call_back(const char *message)
{
    std::cout << "rep : [" << message << "] " << std::endl;
}
